const http = require('http');
const WebSocket = require('websocket').server; // 注意这里改为WebSocket
const moment = require('moment');

let onLineStatus = false //服务器默认不在线

//创建http服务器
const httpSever = http.createServer((req,res)=>{
    res.writeHead(404);
    res.end();
}); // 注意这里加上了";"

//创建websocket服务器
const wsSever = new WebSocket({
    httpServer: httpSever, // 将httpSever实例传递给WebSocket服务器
    autoAcceptConnections: true //自动接受连接
});

//监控接入
wsSever.on('connect',(connection)=>{
    //监控数据信息message
    connection.on('message',(msg)=>{
        console.log('>> message' , msg)
        if(msg.type === 'utf8' && !onLineStatus){
            var data = {
                content : '[自动回复] : 我是龙！强者就是要羞辱弱者！',
                date : moment(new Date()).format('YYYY-D-M', 'h:mm a')
            }
            connection.sendUTF( JSON.stringify(data))
        }
    })

    //监控关闭
    connection.on('close',()=>{
        console.log('socket服务关闭');
    })
    //服务器发送数据到客户端需要监控数据
    process.stdin.on('data',(data)=>{
        var data = data.toString().trim() //清除前后空格
        data = {
            content :data,
            date : moment(new Date()).format('YYYY-D-M , h:mm a')
        }
        connection.sendUTF(JSON.stringify(data)); //发送
    })
})

httpSever.listen(3000,()=>{
    console.log('白银低分狗')
})